package cn.xianshu._01_base;

import cn.xianshu.util.ConnectionUtil;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class Consumer {

    public static void main(String[] args) throws Exception {
        //1.创建链接
        Connection connection = ConnectionUtil.getConnection();

        //2.创建通道
        //3.监听队列
        //4.拿到消息
        //5处理消息
    }
}
